package com.at.bigdata.spark.core.framework.dao

import com.at.bigdata.spark.core.framework.common.TDao
import com.at.bigdata.spark.core.framework.util.EnvUtil
import org.apache.spark.rdd.RDD

/**
 *
 * @author cdhuangchao3
 * @date 2023/5/20 9:25 PM
 */
class WordCountDao extends TDao{

  def readFile(path: String): RDD[String] = {
    EnvUtil.take().textFile(path)
  }
}
